﻿using System;
using System.IO;
using System.Data.SqlServerCe;
using NHibernate.Tool.hbm2ddl;

namespace MoroMoro.Samples.ToDoList.Persistence.NHibernate
{
    /// <summary>
    /// SQL Server CE 4.0 データベースを表します。
    /// </summary>
    public sealed class Database : IDataStore
    {
        /// <summary>
        /// <see cref="Database"/> クラスの新しいインスタンスを初期化します。
        /// </summary>
        /// <param name="directoryPath">ディレクトリのパス。</param>
        /// <param name="fileName">データベースファイルの名前。</param>
        /// <exception cref="System.ArgumentException">directoryPath または fileName が無効な文字を含んでいます。</exception>
        /// <exception cref="System.ArgumentNullException">directoryPath または fileName が null です。</exception>
        public Database(string directoryPath, string fileName)
        {
            _connectionString = new ConnectionString(directoryPath, fileName);
        }


        /// <summary>
        /// SQL Server CE 4.0 接続文字列。
        /// </summary>
        private readonly ConnectionString _connectionString;


        /// <summary>
        /// データストアが存在するかどうかを示す値を取得します。
        /// </summary>
        /// <returns>データストアが存在する場合は true、それ以外は false。</returns>
        public bool Exists()
        {
            return File.Exists(_connectionString.FilePath);
        }

        /// <summary>
        /// データストアを生成します。
        /// </summary>
        /// <exception cref="System.InvalidOperationException">データストアは既に存在しています。</exception>
        public void Create()
        {
            if (Exists())
            {
                throw new InvalidOperationException();
            }

            if (!Directory.Exists(_connectionString.DirectoryPath))
            {
                Directory.CreateDirectory(_connectionString.DirectoryPath);
            }

            using (var engine = new SqlCeEngine(_connectionString))
            {
                engine.CreateDatabase();
            }

            try
            {
                var configuration = NHConfig.GetConfiguration(_connectionString);
                var schemaExport = new SchemaExport(configuration);
                schemaExport.Execute(true, true, false);
            }
            catch
            {
                File.Delete(_connectionString.FilePath);
                throw;
            }
        }
    }
}
